/**
 * Created by Administrator on 2025/5/9.
 * */
#include "InterferenceSource.h"

BaseObject *createInterferenceSource() {
    return new InterferenceSource();
}

void destroyInterferenceSource(BaseObject *p) {
    SAFE_DELETE(p);
}

InterferenceSource::InterferenceSource(){
}

InterferenceSource::~InterferenceSource() {
}

/* 如果使用了DDS_Reader或者DDS_Writer，则对应的input或者output前64个字节为DataFormat head首部 */
void InterferenceSource::onCompute(buffer_table_t *input, buffer_table_t *output) {
LOG_INFO("(%lld)onCompute:%s", this->outputSequence, this->instanceName.c_str());

  /** 获取端口数据指针示例
   * const char *src0 = input->list[0]->data;
   * char *dest0 = output->list[0]->data;
   * */


  /** 计算示例
   * if (input->list[0]->valid) {
   *     memcpy(dest0, src0, std::min(input->list[0]->len, output->list[0]->len));
   *   }
   * */
}
